package com.alphay.boot.system.service.impl;

import java.util.*;

import cn.hutool.core.collection.CollUtil;
import com.alphay.boot.common.annotation.DataScope;
import com.alphay.boot.common.constant.UserConstants;
import com.alphay.boot.common.core.domain.entity.SysRole;
import com.alphay.boot.common.core.domain.entity.SysUser;
import com.alphay.boot.common.exception.ServiceException;
import com.alphay.boot.common.mybatis.service.ServiceImplX;
import com.alphay.boot.common.utils.collection.CollectionUtil;
import com.alphay.boot.common.utils.spring.SpringUtils;
import com.alphay.boot.common.enums.SystemStatusEnum;
import com.alphay.boot.system.common.domain.SysUserGroupRole;
import com.alphay.boot.system.mapper.*;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.alphay.boot.common.utils.SecurityUtils;
import com.alphay.boot.common.utils.StringUtils;
import com.alphay.boot.system.common.domain.SysRoleDept;
import com.alphay.boot.system.common.domain.SysRoleMenu;
import com.alphay.boot.system.common.domain.SysUserRole;
import com.alphay.boot.system.common.service.ISysRoleService;

/**
 * 角色 业务层处理
 *
 * @author d3code
 */
@Service
public class SysRoleServiceImpl extends ServiceImplX<SysRoleMapper, SysRole>
    implements ISysRoleService {

  @Autowired private SysRoleMenuMapper roleMenuMapper;

  @Autowired private SysUserRoleMapper userRoleMapper;

  @Autowired private SysRoleDeptMapper roleDeptMapper;

  @Autowired private SysUserGroupRoleMapper userGroupRoleMapper;

  /**
   * 根据条件分页查询角色数据
   *
   * @param role 角色信息
   * @return 角色数据集合信息
   */
  @Override
  @DataScope(deptAlias = "d.dept_id")
  public List<SysRole> selectRoleList(SysRole role, IPage page) {
    return this.baseMapper.selectRoleList(role, page);
  }

  /**
   * 根据用户ID查询角色
   *
   * @param userId 用户ID
   * @return 角色列表
   */
  @Override
  public List<SysRole> selectRolesByUserId(Long userId) {
    List<SysRole> userRoles = this.baseMapper.selectRolePermissionByUserId(userId);
    List<SysRole> roles = selectRoleAll();
    for (SysRole role : roles) {
      for (SysRole userRole : userRoles) {
        if (role.getRoleId().longValue() == userRole.getRoleId().longValue()) {
          role.setFlag(true);
          break;
        }
      }
    }
    return roles;
  }

  /**
   * 根据用户ID查询权限
   *
   * @param userId 用户ID
   * @return 权限列表
   */
  @Override
  public Set<String> selectRolePermissionByUserId(Long userId) {
    List<SysRole> perms = this.baseMapper.selectRolePermissionByUserId(userId);
    Set<String> permsSet = new HashSet<>();
    for (SysRole perm : perms) {
      if (StringUtils.isNotNull(perm)) {
        permsSet.addAll(Arrays.asList(perm.getRoleKey().trim().split(",")));
      }
    }
    return permsSet;
  }

  /**
   * 查询所有角色
   *
   * @return 角色列表
   */
  @Override
  public List<SysRole> selectRoleAll() {
    return SpringUtils.getAopProxy(this).selectRoleList(new SysRole());
  }

  /**
   * 根据用户ID获取角色选择框列表
   *
   * @param userId 用户ID
   * @return 选中角色ID列表
   */
  @Override
  public List<Long> selectRoleListByUserId(Long userId) {
    return this.baseMapper.selectRoleListByUserId(userId);
  }

  /**
   * 通过角色ID查询角色
   *
   * @param roleId 角色ID
   * @return 角色对象信息
   */
  @Override
  public SysRole selectRoleById(Long roleId) {
    return this.baseMapper.selectRoleById(roleId);
  }

  /**
   * 校验角色名称是否唯一
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  public String checkRoleNameUnique(SysRole role) {
    Long roleId = StringUtils.isNull(role.getRoleId()) ? -1L : role.getRoleId();
    SysRole info = this.baseMapper.checkRoleNameUnique(role.getRoleName());
    if (StringUtils.isNotNull(info) && info.getRoleId().longValue() != roleId.longValue()) {
      return UserConstants.NOT_UNIQUE;
    }
    return UserConstants.UNIQUE;
  }

  /**
   * 校验角色权限是否唯一
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  public String checkRoleKeyUnique(SysRole role) {
    Long roleId = StringUtils.isNull(role.getRoleId()) ? -1L : role.getRoleId();
    SysRole info = this.baseMapper.checkRoleKeyUnique(role.getRoleKey());
    if (StringUtils.isNotNull(info) && info.getRoleId().longValue() != roleId.longValue()) {
      return UserConstants.NOT_UNIQUE;
    }
    return UserConstants.UNIQUE;
  }

  /**
   * 校验角色是否允许操作
   *
   * @param role 角色信息
   */
  @Override
  public void checkRoleAllowed(SysRole role) {
    if (StringUtils.isNotNull(role.getRoleId()) && role.isAdmin()) {
      throw new ServiceException("不允许操作超级管理员角色");
    }
  }

  /**
   * 校验角色是否有数据权限
   *
   * @param roleId 角色id
   */
  @Override
  public void checkRoleDataScope(Long roleId) {
    if (!SysUser.isAdmin(SecurityUtils.getUserId())) {
      SysRole role = new SysRole();
      role.setRoleId(roleId);
      List<SysRole> roles = SpringUtils.getAopProxy(this).selectRoleList(role);
      if (StringUtils.isEmpty(roles)) {
        throw new ServiceException("没有权限访问角色数据！");
      }
    }
  }

  /**
   * 通过角色ID查询角色使用数量
   *
   * @param roleId 角色ID
   * @return 结果
   */
  @Override
  public int countUserRoleByRoleId(Long roleId) {
    return userRoleMapper.countUserRoleByRoleId(roleId);
  }

  /**
   * 新增保存角色信息
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  @Transactional
  public boolean save(SysRole role) {
    // 新增角色信息
    boolean result = super.save(role);
    if (result) {
      insertRoleMenu(role);
    }
    return result;
  }

  /**
   * 修改保存角色信息
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  @Transactional
  public boolean updateById(SysRole role) {
    // 修改角色信息
    boolean result = super.updateById(role);
    if (result) {
      // 删除角色与菜单关联
      roleMenuMapper.deleteRoleMenuByRoleId(role.getRoleId());
      insertRoleMenu(role);
    }
    return result;
  }

  /**
   * 修改角色状态
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  public int updateRoleStatus(SysRole role) {
    return this.baseMapper.updateById(role);
  }

  /**
   * 修改数据权限信息
   *
   * @param role 角色信息
   * @return 结果
   */
  @Override
  @Transactional
  public int authDataScope(SysRole role) {
    // 修改角色信息
    super.updateById(role);
    // 删除角色与部门关联
    roleDeptMapper.deleteRoleDeptByRoleId(role.getRoleId());
    // 新增角色和部门信息（数据权限）
    return insertRoleDept(role);
  }

  /**
   * 新增角色菜单信息
   *
   * @param role 角色对象
   */
  public int insertRoleMenu(SysRole role) {
    int rows = 1;
    // 新增用户与角色管理
    List<SysRoleMenu> list = new ArrayList<SysRoleMenu>();
    for (Long menuId : role.getMenuIds()) {
      SysRoleMenu rm = new SysRoleMenu();
      rm.setRoleId(role.getRoleId());
      rm.setMenuId(menuId);
      list.add(rm);
    }
    if (list.size() > 0) {
      rows = roleMenuMapper.batchRoleMenu(list);
    }
    return rows;
  }

  /**
   * 新增角色部门信息(数据权限)
   *
   * @param role 角色对象
   */
  public int insertRoleDept(SysRole role) {
    int rows = 1;
    // 新增角色与部门（数据权限）管理
    List<SysRoleDept> list = new ArrayList<SysRoleDept>();
    for (Long deptId : role.getDeptIds()) {
      SysRoleDept rd = new SysRoleDept();
      rd.setRoleId(role.getRoleId());
      rd.setDeptId(deptId);
      list.add(rd);
    }
    if (list.size() > 0) {
      rows = roleDeptMapper.batchRoleDept(list);
    }
    return rows;
  }

  /**
   * 通过角色ID删除角色
   *
   * @param roleId 角色ID
   * @return 结果
   */
  @Override
  @Transactional
  public int deleteRoleById(Long roleId) {
    // 删除角色与菜单关联
    roleMenuMapper.deleteRoleMenuByRoleId(roleId);
    // 删除角色与部门关联
    roleDeptMapper.deleteRoleDeptByRoleId(roleId);
    return this.baseMapper.deleteRoleById(roleId);
  }

  /**
   * 批量删除角色信息
   *
   * @param roleIds 需要删除的角色ID
   * @return 结果
   */
  @Override
  @Transactional
  public int deleteRoleByIds(Long[] roleIds) {
    for (Long roleId : roleIds) {
      checkRoleAllowed(new SysRole(roleId));
      checkRoleDataScope(roleId);
      SysRole role = selectRoleById(roleId);
      if (countUserRoleByRoleId(roleId) > 0) {
        throw new ServiceException(String.format("%1$s已分配,不能删除", role.getRoleName()));
      }
    }
    // 删除角色与菜单关联
    roleMenuMapper.deleteRoleMenu(roleIds);
    // 删除角色与部门关联
    roleDeptMapper.deleteRoleDept(roleIds);
    return this.baseMapper.deleteRoleByIds(roleIds);
  }

  /**
   * 取消授权用户角色
   *
   * @param userRole 用户和角色关联信息
   * @return 结果
   */
  @Override
  public int deleteAuthUser(SysUserRole userRole) {
    return userRoleMapper.deleteUserRoleInfo(userRole);
  }

  /**
   * 批量取消授权用户角色
   *
   * @param roleId 角色ID
   * @param userIds 需要取消授权的用户数据ID
   * @return 结果
   */
  @Override
  public int deleteAuthUsers(Long roleId, Long[] userIds) {
    return userRoleMapper.deleteUserRoleInfos(roleId, userIds);
  }

  /**
   * 批量选择授权用户角色
   *
   * @param roleId 角色ID
   * @param userIds 需要授权的用户数据ID
   * @return 结果
   */
  @Override
  public int insertAuthUsers(Long roleId, Long[] userIds) {
    // 新增用户与角色管理
    List<SysUserRole> list = new ArrayList<SysUserRole>();
    for (Long userId : userIds) {
      SysUserRole ur = new SysUserRole();
      ur.setUserId(userId);
      ur.setRoleId(roleId);
      list.add(ur);
    }
    return userRoleMapper.batchUserRole(list);
  }

  @Override
  public int insertAuthUserGroups(Long roleId, Long[] userGroupIds) {
    // 新增用户与角色管理
    List<SysUserGroupRole> list = new ArrayList<SysUserGroupRole>();
    for (Long groupId : userGroupIds) {
      SysUserGroupRole ur = new SysUserGroupRole();
      ur.setGroupId(groupId);
      ur.setRoleId(roleId);
      list.add(ur);
    }
    return userGroupRoleMapper.batchUserGroupRole(list);
  }

  @Override
  public void validateRoleList(Collection<Long> ids) {
    if (CollUtil.isEmpty(ids)) {
      return;
    }
    // 获得角色信息
    List<SysRole> roles = this.baseMapper.selectBatchIds(ids);
    Map<Long, SysRole> roleMap = CollectionUtil.convertMap(roles, SysRole::getRoleId);
    // 校验
    ids.forEach(
        id -> {
          SysRole role = roleMap.get(id);
          if (role == null) {
            throw new ServiceException("角色不存在");
          }
          if (!SystemStatusEnum.ENABLE.getStatus().equals(role.getStatus())) {
            throw new ServiceException("名字为【" + role.getRoleName() + "】的角色已被禁用");
          }
        });
  }

  @Override
  public List<SysUserRole> selectUserRoleListByRoleIds(Collection<Long> ids) {
    return userRoleMapper.selectUserRoleListByRoleIds(ids);
  }

  @Override
  public int deleteAuthUserGroup(SysUserGroupRole groupRole) {
    return userGroupRoleMapper.deleteUserGroupRoleInfo(groupRole);
  }

  @Override
  public int deleteAuthUserGroups(Long roleId, Long[] userGroupIds) {
    return userGroupRoleMapper.deleteUserGroupRoleInfos(roleId, userGroupIds);
  }
}
